package com.gitee.window.connect

import com.gitee.utils.KafkaConsumerProps
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer011

object KafkaSource {
  def getKafkaStreamData(topic:String): FlinkKafkaConsumer011[String] ={
    new FlinkKafkaConsumer011[String](topic,new SimpleStringSchema(),KafkaConsumerProps.getProperties())
  }
}
